const mysql = require('mysql');

function query(sql, params) {
    // 创建连接配置
    const con = mysql.createConnection({
        host: 'localhost',
        port: 3306,
        user: 'root',
        password: 'root',
        database: 'case-invoice',
    });

    // 连接 mysql
    // con.connect((error) => {
    //     if (error) return console.log('数据库连接失败', error.message);
    // });

    // 发送 SQL 语句到 MySQL 服务器，操作 MySQL 服务器的数据
    return new Promise((resolve, reject) => {
        con.query(sql, params, (error, result) => {
            // if (error) return console.log('插入数据失败了', error.message);
            if (error) return reject(error);
            // 成功了，返回数据
            resolve(result);
        });

        // 关闭连接
        con.end();
    });
}

module.exports = { query };
